package com.gemframe.kafka;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface Source {
	
	//发送队列1
	String OUTPUT_1 = "sourceA";
	
	@Output(Source.OUTPUT_1)
	MessageChannel output1();
	
}
